package com.jsean.core.repository;

import java.util.Map;

public interface OffsetRepository {
    long getOffset(String consumerId);
    void setOffset(String consumerId, long offset);
    void persistAll(Map<String, Long> offsets);
    Map<String, Long> loadAll();
}